package com.tepth.busfix.base;

import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.observers.DisposableObserver;

/**
 * Created by zhangyu on 2016/6/30.
 */
public class RxManager {
    /**
     * 管理订阅者
     */
    private CompositeDisposable mCompositeSubscription = new CompositeDisposable();

    public void add(DisposableObserver sp) {
        mCompositeSubscription.add(sp);
    }

    public void clear() {
        //取消订阅
        mCompositeSubscription.clear();

    }
}
